from celery import Celery
from django.conf import settings
import os

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'dadablong.settings')       # 在Linux中添加环境变量

app = Celery('dadablong')
app.conf.update(

    BROKER_URL = 'redis://@127.0.0.1:6379/1'
)

# 自动去注册应用下寻找加载worker函数
app.autodiscover_tasks(settings.INSTALLED_APPS)